.NET Core分布式事务CAP2.6之控制台使用

（给DotNet加星标，提升.Net技能）

转自：sunyuliang

cnblogs.com/sunyuliang/p/11447565.html

上一篇讲了 《CAP 2.6的快速入门》，这次我们来讲讲在控制台中如何使用CAP 2.6。因为CAP 2.6的内存模式目前已经可以使用了，相关组件已经更新，所以这次我们以简单的内存模式为例。

一、创建项目

创建一个名叫CAPConsoleDemo的"控制台应用(.NET Core)"程序，.NET Core版本要求在2.2或以上。

二、添加相关引用

在nuget中添加 DotNetCore.CAP  DotNetCore.CAP.InMemoryStorage  Savorboard.CAP.InMemoryMessageQueue  Microsoft.Extensions.Hosting 等组件的引用。 

三、构建常规Host主机

常规host主机是.NET Core 2.1中引入的，本质是移除了web功能的webhost，以前webhost的所有依赖注入，生命周期管理，日志管理等都可以在控制台程序中使用。以后webhost都会是基于常规host来实现的。

实现方式也很简单，只要将Programe.cs中改成下面这样就好了

using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;
using Savorboard.CAP.InMemoryMessageQueue;
using System;

namespace CAPConsoleDemo
{
    class Program
    {
        static void Main(string[] args)
        {
            CreateHostBuilder(args).Build().Run();  //构建一个常规Host
        }
        static IHostBuilder CreateHostBuilder(string[] args)
        {
            var build = new HostBuilder();
            build.ConfigureServices((hostContext, services) =>
            {
                services.AddCap(option =>      //添加CAP框架
                {
                    option.UseInMemoryStorage();   //使用内存存储
                    option.UseInMemoryMessageQueue();  //使用内存队列
                    option.UseDashboard();  //添加监控仪表盘
                });
            });
            return build;
        }
    }
}

四、添加推送程序

4.1、添加一个继承自IHostedService的Publish类，并在里面创建一个定时器，每秒推送一次事件。

using DotNetCore.CAP;
using Microsoft.Extensions.Hosting;
using System;
using System.Threading;
using System.Threading.Tasks;

namespace CAPConsoleDemo
{
    public class Publish : IHostedService
    {
        private ICapPublisher capPublish;  //CAP发布程序
        private Timer _timer;   //定时器
        public Publish(ICapPublisher capPublish)  //自动注入CAP程序
        {
            this.capPublish = capPublish;
        }
        public Task StartAsync(CancellationToken cancellationToken)
        {
            _timer = new Timer(work, null, TimeSpan.Zero, TimeSpan.FromSeconds(1));  //每秒运行一次推送任务
            return Task.CompletedTask;
        }
        private void work(object state)
        {
            capPublish.Publish<string>("Order.Created", DateTime.Now.ToString());  //推送Order.Created事件
            Console.WriteLine("推送：" + DateTime.Now.ToString());
        }
        public Task StopAsync(CancellationToken cancellationToken)
        {
            return Task.CompletedTask;
        }
    }
}

4.2、在Programe.CreateHostBuilder方法中添加推送服务 services.AddHostedService<Publish>();  

4.3、f5运行程序，此时是已经可以正常推送消息了。

五、添加监听服务

5.1、创建一个承继自ICapSubscribe接口的类Events，并监听Order.Created事件，代码如下： 

using DotNetCore.CAP;
using System;
using System.Threading.Tasks;

namespace ConsoleApp2
{
    public class Events : ICapSubscribe
    {
        [CapSubscribe("Order.Created")]   //监听Order.Created事件
        public async Task OrderCreatedEventHand(string msg)
        {
            Console.WriteLine("--接收："+ msg);
        }
    }
}

5.2、在在Programe.CreateHostBuilder方法中添加监听服务 services.AddSingleton<ICapSubscribe, Events>(); 

六、大功造成

F5运行程序，可以看到程序在一边推送一边接收。

七、同一事件，多个服务监听处理

默认情况下，一个事件只会被一个监听者处理，即使我们创建了多个服务来监听同一事件，也只会有一个服务收到此事件，其它服务是收不到的。那么怎么让多个服务同时处理同一事件呢？答案是使用分组，在添加监听器时使用不同的分组名称。

7.1、我们将Events类中的代码，稍微改动一下，使用两个都监听Order.Created事件的方法，但命名成不同的分组。

using DotNetCore.CAP;
using System;
using System.Threading.Tasks;

namespace CAPConsoleDemo
{
    public class Events : ICapSubscribe
    {
        [CapSubscribe("Order.Created", Group = "Group1")]   //监听Order.Created事件,并命名为Group1
        public async Task OrderCreatedEventHand(string msg)
        {
            Console.WriteLine("--Group1接收：" + msg);
        }
        [CapSubscribe("Order.Created", Group = "Group2")]   //监听Order.Created事件,并命名为Group2
        public async Task Group2(string msg)
        {
            Console.WriteLine("--Group2接收：" + msg);
        }
    }
}

7.2、F5运行，如下图所示，一次推送事件，两个监听服务都处理了此事件。

代码下载：https://pan.baidu.com/s/1X2uCvcLjQ9AiqxMD3CtTcA

推荐阅读  点击标题可跳转

看完本文有收获？请转发分享给更多人

关注「DotNet」加星标，提升.Net技能 

好文章，我在看❤️